package com.sencorsta.ids.queue;

public class MqWorker implements Runnable {

	@Override
	public void run() {
		while (true) {
			try {
				//Thread.sleep(1200l);
				String o=QueueTest.q.poll();
				if (o!=null) {
					System.out.println("消费:"+o);
				}
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

}
